package iwb.utils.kafkapatition;

import araf.jobexecution.parallelframework.ArafPublish;
import araf.jobexecution.vo.ArafPubSubKey;
import iwb.messagequeue.domainmodel.vo.TestMessageVO;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;


@Component
@Slf4j
@Data
public class PartitionExecPublish extends ArafPublish<Messager> {

    private String dataTypeId;

    @Override
    public String getDataTypeId() {
        return this.dataTypeId;
    }

    @Override
    protected void onSendFailure(ArafPubSubKey k, Messager testMessageVO, Throwable ex) {
//        log.error(testMessageVO.toString());
        log.error(testMessageVO.toString());
    }
}
